//开始与服务器通信
joinListen();
//取消debug模式
PL.setDebug(false);
//封装在线用户
var onlines = new Array();


 // 服务器回调事件
function onEvent(event) {

	var divId = $("#cw" + event.get("p_from")).html();
	// 添加好有 或是 更新时间戳
	if (event.getSubject() == "/user/login" && PL.sessionId != event.get("p_from") && divId == null) {
		var url = "UserServlet?cmd=addORupdate&p_from=" + event.get("p_from") + "&name=" + event.get("name") + "&p_time=" + event.get("p_time");
		url = encodeURI(url);
		$.post(url, null, function (date) {
			//添加好有
			var cw = $("#cw").html();
			$("#cw").html(cw + date);
		});
	}
	 //如果是聊天的信息   
	if (event.getSubject() == "/user/chat") {
		alert("\u804a\u5929\u7684\u4fe1\u606f");
	}
}

//与服务器建立连接 建立session  并监听事件
//   /pushlet/ping  是为了与服务器保持心跳  知道服务器没死
//   /user/login  登陆信息  /user/login  聊天信息
function joinListen() {
	PL.joinListen("/pushlet/ping,/user/login,/user/chat");
}
	
//发布上线信息
function publish() {
	PL.publish("/user/login", "name=" + $("#name").val());
}

//上线后马上发布我的上线信息
function onJoinListenAck(event) {
	publish();
}
	
	
//借助一定周期的RefreshAck事件  发送我的在线信息
//是为了提供给刚上线的user 并监控在线用户的时间戳是否较新  否则判断为掉线 踢掉
//Refresh是为了让服务器知道client没死
function onRefreshAck(event) {
	//alert(event.get("p_time")+"---"+event.get("p_from"));
	//publish();
}

